package org.sss.mapreduce.example;

import org.sss.mapreduce.Mapper;
import org.sss.mapreduce.Output;
import org.sss.mapreduce.datatype.DCPackableBytes;
import org.sss.mapreduce.datatype.PackableBytes;

/**
 * Just vacuum <DCPackableBytes, PackableBytes> records.
 */
public class VacuumMapper extends Mapper {
  public void map(Context context, DCPackableBytes key, PackableBytes value,
      Output<DCPackableBytes, PackableBytes> output) throws Exception {
    //
    // DO NOTHING, JUST THROW AWAY THE INPUT RECORDS.
    //
  }
}
